package com.gitee.xhs.windowState;

import org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows;
import org.apache.flink.streaming.api.windowing.time.Time;

import static com.gitee.xhs.StateConstant.FLINK_CHECK_POINT_PATH;

/**
 * @author BigHead
 * @date 2022/7/7 15:08
 * @description WindowStateConstant
 */
public class WindowStateConstant {

    public static final String CUSTOM_WINDOW_STATE_DIR = "windowState/";

    public static final String WINDOW_STATE_PATH = FLINK_CHECK_POINT_PATH + CUSTOM_WINDOW_STATE_DIR;
    public static final String WINDOW_STATE_UID = "window-state-uid";
    public static final TumblingEventTimeWindows TUMBLING_EVENT_TIME_WINDOWS_ONE_MINUTE = TumblingEventTimeWindows.of(Time.minutes(1));

}
